package insurance

import org.apache.spark.sql.SparkSession

object ExampleSql{


  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .master("local")
      .appName("MonitorFlowAnalyzer")
      .enableHiveSupport()
      .getOrCreate()
    spark.sparkContext.setLogLevel("WARN")

    //,concat_ws(',',collect_set(camera_id)) cameraIds

    val sql1 = "select * from insurance_app.app_agg_month_cooloff_surr"
    val df1 = spark.sql(sql1)
    df1.show()


    spark.close()
  }
}
